/**     
 * @Title: MessageListener.java   
 * @Package me.xxy.mq   
 * @Description: TODO
 * @author weiwei 
 * @date 2018年5月30日 下午5:01:50   
 * @version V1.0     
 */
package me.xxy.mq.core;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

/**
 * @ClassName: MessageListener
 * @Description: TODO
 * @author weiwei
 * @date 2018年5月30日 下午5:01:50
 * 
 */
@Service
public class MessageListener {

	@Autowired
	private RedisConfig redisConfig;

	/**
	 * @Title: getMessageCount
	 * @Description: 获取待处理消息个数
	 * @param messageType
	 * @Reutrn int
	 */
	public int getMessageCount(String messageType) {
		return redisConfig.llen(messageType).intValue();
	}
}
